package register

import (
	"github.com/liuxd6825/dapr-go-ddd-sdk/restapp"
)

// 所有注册的消息订阅
var _subscribes = make([]restapp.RegisterSubscribe, 0)

//
// GetRegisterSubscribe
// @Description: 获取所有注册的消息订阅
// @return []restapp.RegisterSubscribe
//
func GetRegisterSubscribe() []restapp.RegisterSubscribe {
	return _subscribes
}

//
// AddSubscribe
// @Description: 添加消息订阅
// @param subs
//
func AddSubscribe(subs ...restapp.RegisterSubscribe) {
	for _, sub := range subs {
		_subscribes = append(_subscribes, sub)
	}
}

//
//  initSubscribe
//  @Description: 初始化消息订阅
//
func initSubscribe() {

}
